package com.ustcinfo.ishare.kafka.monitor.service;

import com.ustcinfo.ishare.kafka.monitor.bean.KafkaMonitorInfo;
import org.apache.ibatis.annotations.Param;

import java.util.List;


/**
 * Created by Shinelon on 2018/3/24.
 */
public interface IKafkaInfoService {

    public  void getAllKafkaInfo();

    public void insert(KafkaMonitorInfo kafkaMonitorInfo);

    public void removeAll();

    public void removeByTopic(@Param("topic")String topic);

    public List<KafkaMonitorInfo> findKafkaMonitorInfoByTopic(String topic);

    public List<KafkaMonitorInfo> findAllKafkaMonitorInfo();

    public List<KafkaMonitorInfo> findKafkaMonitorInfoByPage(@Param("pageStart") int start,@Param("pageSize")int size);

    public List<KafkaMonitorInfo> findKafkaMonitorInfo(@Param("topicName") String topicName ,@Param("groupName") String groupName ,@Param("beginTimeValue") Long beginTime ,@Param("endTimeValue") Long endTime);
}
